package concurrent.queue;


import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;

public class LinkedBlockingQueueDemo {

    public static void main(String[] args) throws InterruptedException {
        LinkedBlockingQueue<Long>  queue = new LinkedBlockingQueue<>(10);
        ArrayBlockingQueue<Long> longs = new ArrayBlockingQueue<Long>(10);
        System.out.println(queue.size());
        queue.put(1L);
        queue.put(2L);
        Long take = queue.take();
        System.out.println( take);;
        System.out.println(  queue.size());

    }
}
